package cn.kgc.service;

import cn.kgc.entity.Messageinfo;

/**
 * @author wangyue
 * @version 1.0
 */
public interface ConsumerMessageInfoService {
    /**
     * 如果消息处理成功 从队列中删除消息
     */
    void messageReceiveSuccess(String id);

    /**
     * 判断消息是否是第一次消费如果是第一次消费将其保存到数据库中否则更新消费次数
     */
    Messageinfo messageReceiveReady(String id, String exchange, String routingKey,
                                    String queue, String body, long delayTime);

    /**
     * 消息多次消费,消息死亡
     */
    void messageReceiveDead(String id);
}
